package com.neusoft.hifly.kafka.consumer;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import com.neusoft.hifly.core.log.Log;

/**
 * 消费者监听topic的消息
 */
@Component
public class ConsumerListener {

	@KafkaListener(topics = "micro-netty")
	public void onMessage(String message) {
		Log.info("Kafka 客户端接收到（micro-netty）消息：" + message);
	}

	//	在slave1,slave2,slave3主机上分别启动 Kafka 服务：
	//	cd /home/kafka_2.11-2.3.1/bin
	//	./kafka-server-start.sh ../config/server.properties &

	//	在slave1(192.168.66.43)上创建一个名为 micro-netty，拥有两个分区，两个副本的Topic
	//	cd /home/kafka_2.11-2.3.1/
	//	bin/kafka-topics.sh --create --zookeeper slave1:2181,slave2:2181,slave3:2181 --replication-factor 2 --partitions 2 --topic micro-netty

}
